package org.lennon.compent.aliyun.rocketmq.starter.sampleexemple.processor.extend;

import org.lennon.compent.aliyun.rocketmq.client.consistent.persist.IRocketMQPersistent;
import org.lennon.compent.aliyun.rocketmq.client.consistent.persist.entity.MessageConsumerFailureTable;
import org.lennon.compent.aliyun.rocketmq.client.consistent.persist.entity.MessageConsumerHistoryTable;
import org.lennon.compent.aliyun.rocketmq.client.consistent.persist.entity.MessageTable;
import org.springframework.stereotype.Component;

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

/**
 * 自实现持久化接口
 *
 */
@Component
public class MyRocketMQPersistent implements IRocketMQPersistent {

    @Override
    public Integer persistMessage(MessageTable messageTable) {
        return 0;
    }

    @Override
    public List<MessageTable> queryMessage(Timestamp startTime, Timestamp endTime) {
        return new ArrayList<>();
    }

    @Override
    public Integer deleteMessage(MessageTable messageTable) {
        return 0;
    }

    @Override
    public List<MessageTable> queryMessage(Timestamp startTime, Timestamp endTime, String topic, List<String> tags) {
        return new ArrayList<>();
    }

    @Override
    public Integer persistMessageConsumerHistory(MessageConsumerHistoryTable messageConsumerHistoryTable) {
        return 0;
    }

    @Override
    public Integer persistMessageConsumerFailure(MessageConsumerFailureTable messageConsumerFailureTable) {
        return 0;
    }
}
